package com.atguigu.springcloud.service.impl;

import com.atguigu.springcloud.service.IMessageProvider;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.support.MessageBuilder;

import javax.annotation.Resource;
import java.util.UUID;

/**
 * @author jingchun
 * @create 2024-06-11 21:56
 */


@EnableBinding(Source.class)
public class MessageProviderImpl implements IMessageProvider {
	@Resource
//	@Qualifier(org.springframework.cloud.stream.messaging.Source.OUTPUT)
	private MessageChannel output;// 消息的发送管道


	@Override
	public String send() {
		String serial = UUID.randomUUID().toString();
		output.send(MessageBuilder.withPayload(serial).build());// 创建并发送消息

		System.out.println("***serial: "+serial);

		return serial;


	}
}
